package com.cpz.rabbitmq.message;

import com.cpz.rabbitmq.config.RabbitConstants;

/**
 * @author cpz
 * @since 2022/09/19
 */
public class FanoutMessage extends RabbitMessage<String> {
    @Override
    public String exchange() {
        return RabbitConstants.EXCHANGE_FANOUT;
    }

    /**
     * 生产者的routingKey可以为空，因为生产者的所有数据，会下放到每一个队列，所以不会通过routingKey去路由；
     * 消费者需要指定queues，因为消费者需要绑定到指定的queues才能消费。
     * @return
     */
    @Override
    public String routingKey() {
        return null;
    }
}
